#include "msg_queue_peer.h"

struct msgbuf
{
    long mtype;
    char mdata[256];
};

int main(int argc, char *argv[])
{
    struct msgbuf send_buf;

    //这个mtype可以不用，但是必须赋一个不小于0的数
    send_buf.mtype = 1;// 1为modbus 2为单片机
    while (1)
    {
        gets(send_buf.mdata);//读取终端输入的指令，后续修改只需要修改send_buf.mdata的值即可

        if(msg_queue_send("topic", &send_buf, sizeof(send_buf), 0) < 0)//发送 A是modbus,B是stm32
        {
            printf("msg_queue_send error\n");
            return -1;
        }
    }

    return 0;
}